import pika

# 创建认证凭证
credentials = pika.PlainCredentials('admin', 'admin')

# 创建连接参数
parameters = pika.ConnectionParameters(
    host='hwnode2',  # RabbitMQ服务器地址
    port=5672,         # 默认端口
    virtual_host='/',  # 虚拟主机，默认为'/'
    credentials=credentials
)

# 建立连接
connection = pika.BlockingConnection(parameters)
channel = connection.channel()

print("成功连接到 RabbitMQ")

# 使用通道进行操作...

# 关闭连接
connection.close()